<?php

declare (strict_types=1);

namespace addons\Queue\tests;

use app\common\model\Logs;

class TestQueue extends \addons\Queue\driver\Detection
{
    /**
     * 逻辑处理方法
     * @param $data - 接收参数
     * @return bool
     */
    public function handle($data): bool
    {

        try {
            //写日志方法，会在public/queue 下生成当前类名的log文件，请确保public/queue文件夹权限
            $this->writeLog('handle', 1111);
            //逻辑处理...




            //处理完成必须返回true
            return true;
        } catch (\Exception $e) {
            //写入失败日志
            $this->writeLog('handle', '执行失败：【' . $e->getMessage() . '】参数【' . json_encode($data) . '】');
            //返回false，重新回到队列
            return false;
        }

    }

}